a4911a6cd5a14e471c9fc44972f1983c59345318,src/freenet/node/FNPPacketMangler.java,FNPPacketMangler,processOutgoingOrRequeue,#MessageItem[]#PeerNode#boolean#boolean#,996
Before Change
for(int i=0;i<messageData.length;i++) {
MessageItem mi = newMsgs[i];
mi_name = (mi.msg == null ? "(not a Message)" : mi.msg.getSpec().getName());
if(mi.ctrCallback != null) {
mi.ctrCallback.sentBytes(messageData[i].length +
1 + (HEADERS_LENGTH_MINIMUM / messageData.length));
// FIXME rounding issues
}
if(mi.cb != null) {
for(int j=0;j<mi.cb.length;j++) mi.cb[j].sent();
}
}
} catch (NotConnectedException e) {
After Change
try {
innerProcessOutgoing(messageData, 0, messageData.length, length, pn, neverWaitForPacketNumber, callbacks, alreadyReportedBytes);
for(int i=0;i<messageData.length;i++) {
MessageItem mi = newMsgs[i];
mi_name = (mi.msg == null ? "(not a Message)" : mi.msg.getSpec().getName());
mi.onSent(messageData[i].length + 1 + (HEADERS_LENGTH_MINIMUM / messageData.length));
}
} catch (NotConnectedException e) {
Logger.normal(this, "Caught "+e+" while sending messages ("+mi_name+") to "+pn.getPeer()+requeueLogString);